package com.changhong.disruptorsource.quickstart;

import com.lmax.disruptor.EventHandler;

public class OrderEventHandler1 implements EventHandler<OrderEvent>{

	@Override
	public void onEvent(OrderEvent event, long sequence, boolean endOfBatch) throws Exception {
//		Thread.sleep(Integer.MAX_VALUE);
//		if (sequence >= 4) {
//			Thread.sleep(Integer.MAX_VALUE);
//		}
		System.err.println("序号：" + sequence + "，消费者: " + event.getValue());
	}

}
